java - RxJava : How to conditionally apply Operators to an Observable without breaking the chain